const fs = require('fs')
const path = require('path')

const rs = fs.createReadStream(path.join(__dirname, './a.txt')) // 创建一个可读流
const ws = fs.createWriteStream(path.join(__dirname, './c.txt')) // 创建一个可写流
  // 用于处理一些文件比较大的情况，可以分多次把数据写入到内存中

// 监听流的关闭
rs.once('open', () => {
  console.log('可读流打开了');
})

rs.once('close', () => {
  console.log('可读流关闭了');
})

ws.once('open', () => {
  console.log('可写流打开了');
})

ws.once('close', () => {
  console.log('可写流关闭了');

})

rs.pipe(ws) // 将可读流和可写流连接起来